package demo7;

import org.apache.hadoop.mapreduce.Partitioner;

//自定义分区：按照课程名分区
public class SubjectPartition extends Partitioner<DescIntWritable,Subject> {
    @Override          //三个参数分别为：   map输出的 key类型   和 value 类型   分区个数
    public int getPartition(DescIntWritable descIntWritable, Subject subject, int i) {
        String className = subject.getClassName();
        if ("语文".equals(className)){
            return 0;
        } else if ("数学".equals(className)) {
            return 1;
        } else if ("英语".equals(className)) {
            return 2;
        }else {
            return 3;
        }
    }
}
